package fq.simple;

import org.apache.flink.streaming.api.functions.sink.SinkFunction;

public class MySink implements SinkFunction<SinkObj> {
    public void invoke(SinkObj value, Context context) throws Exception {
        System.out.println(value.sum);;
    }
}
